package p.ithorns.framework.redis.stream;


import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.ErrorHandler;


/**
 * RedisStreamErrorHandler
 *
 * @author ithorns
 * @version 1.0.0
 * @date 2022/12/10 13:49
 */
public class RedisStreamErrorHandler implements ErrorHandler {

    private final static Logger log = LoggerFactory.getLogger(RedisStreamErrorHandler.class);

//    @Lazy
//    @Autowired
//    private List<Subscription> subscriptions;

//    @Lazy
//    @Resource(name = "RedisContainers")
//    private List< StreamMessageListenerContainer> redisStreamContainers;

    @Override
    public void handleError(Throwable t) {
        log.error("Redis Stream error: {}", t.getMessage());
    }

}